package cn.ocean._03unid;


import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;

import java.nio.charset.StandardCharsets;

/**
* @Description: 发送异步消息，生产者
* @Author: Fill
* @Version: 1.0
* @Date:  2022/7/25 16:15
*/

public class Producer {

   public static void main(String[] args) throws Exception{

       // 创建生产者对象，指定生产者组名
       DefaultMQProducer producer = new DefaultMQProducer("unid_group_producer");
       // 连接mq
       producer.setNamesrvAddr("127.0.0.1:9876");
       // 启动生产者
       producer.start();
       // 发送消息
       // 创建消息体
       // topic：消息主题 tags：此主题下的二级分类 body：消息的字节
       Message message = new Message("unid", "unid_tags", "我赵洋最帅".getBytes(StandardCharsets.UTF_8));
       // 发送消息
       producer.sendOneway(message);
       // 不在发送消息是关闭消息
       producer.shutdown();

    }
}
